package com.zmm.zebulon.starter.mq.redis.core.interceptor;

import com.zmm.zebulon.starter.mq.redis.core.message.AbstractRedisMessage;

/**
 * description: {@link AbstractRedisMessage} 消息拦截器<br>
 * 通过拦截器，作为插件机制，实现拓展。<br>
 * 例如说，多租户场景下的 MQ 消息处理
 *
 * @author zebulon
 * package com.zmm.zebulon.starter.mq.redis.core.interceptor
 * name: RedisMessageInterceptor
 * date 2024/1/7 15:48
 */
public interface RedisMessageInterceptor {

    default void sendMessageBefore(AbstractRedisMessage message) {
    }

    default void sendMessageAfter(AbstractRedisMessage message) {
    }

    default void consumeMessageBefore(AbstractRedisMessage message) {
    }

    default void consumeMessageAfter(AbstractRedisMessage message) {
    }


}
